package com.guchenbo.flink;

/**
 * @author guchenbo
 * @date 2024/6/10
 */
//public class TransactionGenerator implements SourceFunction<Transaction> {
//    @Override
//    public void run(SourceContext<Transaction> ctx) throws Exception {
//        TransactionSupplier transactions = new TransactionSupplier();
//
//        for (int i = 0; i < 10; i++) {
//            Transaction transaction = transactions.get();
//        }
//    }
//
//    @Override
//    public void cancel() {
//
//    }
//}
